5656
21676
أنا أعمل مع عامل إعادة المحاولة في RxSwift. ووفقًا لوثائقه ، فإنه "يعيد الاشتراك" في المصدر الذي يمكن ملاحظته عندما يواجه خطأً.
هذا هو كل شيء حسن وجيد. ومع ذلك ، لست متأكدًا تمامًا من كيفية التفكير بشأن "المصدر الذي يمكن ملاحظته" عندما يحتوي على عناصر ملحوظة ساخنة ، أو مزيجًا من الملاحظات الساخنة / الباردة.
أنا متأكد من مثال:
let coldObservable = ملحوظ . فترات زمنية (.seconds (1) ، المجدول: MainScheduler.instance)
let coldObservableRetry = coldObservable.flatMapLatest {num in
if num٪ 3 == 0 {return. just (num)}
آخر {return .error ()}
}
.retry (2) // retry تشمل المحاولة الأصلية
coldObservableRetry.subscribe (onNext: {print ($ 0)}) // يطبع 1 ، 2 ، 1 ، 2 ، قبل الخطأ.
مثال لست متأكدًا منه:
let hotObservable = ملحوظ  .interval (.seconds (1) ، المجدول: MainScheduler.instance) .publish ().
اسمح لـ hotObservableRetry = hotObservable.flatMapLatest {num in
if num٪ 3 == 0 {return. just (num)}
آخر {return .error ()}
}
.retry (2)
hotObservableRetry.subscribe (onNext: {print ($ 0)}) // ماذا يحدث هنا؟
مثال آخر لست متأكدًا منه:
let coldObservable = ملحوظ . فترات زمنية (.seconds (1) ، المجدول: MainScheduler.instance)
let delayedHotObservable = ملحوظ . الفاصل الزمني (.seconds (1) ، المجدول: MainScheduler.instance) .delay (.milliseconds (100) ، المجدول: MainScheduler.instance).
let mixObservableRetry = Observable.combineLatest (coldObservable، delayedHotObservable). خريطة {$ 0 + $ 1} .flatMapLatest {num in
if num٪ 3 == 0 {return. just (num)}
آخر {return .error ()}
}
.retry (5)
mixObservableRetry.subscribe (onNext: {print ($ 0)}) // ماذا يحدث هنا؟ ما الذي يعنيه حتى إعادة الاشتراك في مزيج آخر مع حار وبارد يمكن ملاحظته؟
مثال آخر لست متأكدًا منه:
let coldObservable = ملحوظ . فترات زمنية (.seconds (1) ، المجدول: MainScheduler.instance)
let hotObservable = ملحوظ  .interval (.seconds (1) ، المجدول: MainScheduler.instance) .publish (). connect ()
let mixObservable2Retry = coldObservable.flatMapLatest {_ in hotObservable}
.flatMapLatest {num in
if num٪ 3 == 0 {return. just (num)}
آخر {return .error ()}
}
.retry (2)
mixObservable2Retry.subscribe (onNext: {print ($ 0)}) // ماذا يحدث هنا؟ 
لا يتم تجميع العديد من الأمثلة الخاصة بك ، لذا ما يحدث هو أنك تحصل على خطأ في التجميع. :-) لكن للإجابة على السؤال المطروح ...
هناك بعض الأشياء المهمة التي يجب وضعها في الاعتبار.
يشترك كل مشغل في مصدره (مصادره) التي يمكن ملاحظتها ويولد مصدرًا جديدًا يمكن ملاحظته
عند الاشتراك في حالة باردة يمكن ملاحظتها ، فإنها ستبعث 0 ... N من الأحداث التالية ثم حدث توقف (إما مكتمل أو خطأ.) وسيعطي كل اشتراك مجموعة الأحداث الخاصة به.
لا تبدأ الملاحظات الساخنة في الانبعاث حتى يتم استدعاء اتصالها. ستشارك جميع الاشتراكات في نفس مجموعة الأحداث.
أخيرًا في هذه الحالة ، التصحيح هو صديقك.
لذلك بالنسبة لمثالك الأول ، لست متأكدًا منه (تم تعديله بحيث يتم تجميعه وتشغيله مع إضافة بعض عوامل تصحيح الأخطاء):
مثال func () {
let hotObservable = ملحوظ  .interval (.seconds (1) ، المجدول: MainScheduler.instance)
.debug ("قبل النشر")
.ينشر()
دع hotObservableRetry = hotObservable
.debug ("بعد النشر")
.map {(num) -> Int in
حارس num٪ 3! = 0 وإلا {رمي MyError ()}
عودة الأسطوانات
}
.debug ("بعد الخريطة")
.retry (2)
.debug ("بعد إعادة المحاولة")
_ = hotObservableRetry.subscribe ()
_ = hotObservable.connect ()
}
سوف ينتج الناتج أدناه.
فيما يلي بعض الأشياء التي يجب ملاحظتها حول المخرجات التي ستساعد في عملية التعلم.
الاشتراكات تحدث بترتيب عكسي.
بمجرد إصدار الخطأ الأول ، يقوم عامل إعادة المحاولة بالاشتراك في مشغل الخريطة الذي يمكن ملاحظته والذي يعيد الاشتراك في النشر الذي يمكن ملاحظته. نظرًا لأن المنشور الذي يمكن ملاحظته ساخن ، تتوقف سلسلة إعادة الاشتراك هناك. لا يتم إعادة الاشتراك في عداد الوقت الذي يمكن ملاحظته.
ما ورد أعلاه هو النقاط الرئيسية التي يجب فهمها للإجابة على هذا السؤال.
بعد إعادة المحاولة -> مشترك
بعد الخريطة -> مشترك
بعد النشر -> اشترك
قبل النشر -> مشترك
قبل النشر -> الحدث التالي (0)
بعد النشر -> الحدث التالي (0)
بعد الخريطة -> خطأ حدث (MyError ())
بعد الخريطة -> تم التخلص منه
بعد النشر -> تم التخلص منه
بعد الخريطة -> مشترك
بعد النشر -> مشترك
قبل النشر -> الحدث التالي (1)
بعد النشر -> الحدث التالي (1)
بعد الخريطة -> الحدث التالي (1)
بعد إعادة المحاولة -> الحدث التالي (1)
قبل النشر -> الحدث التالي (2)
بعد النشر -> الحدث التالي (2)
بعد الخريطة -> الحدث التالي (2)
بعد إعادة المحاولة -> الحدث التالي (2)
قبل النشر -> الحدث التالي (3)
بعد النشر -> الحدث التالي (3)
بعد الخريطة -> خطأ حدث (MyError ())
بعد إعادة المحاولة -> حدث خطأ (MyError ())
بعد إعادة المحاولة -> تم التخلص منه
بعد الخريطة -> تم التخلص منه
بعد النشر -> تم التخلص منه
قبل النشر -> الحدث التالي (4)
قبل النشر -> الحدث التالي (5)
قبل النشر -> الحدث التالي (6)
...
في المثال التالي الذي عرضته ، أعاد عامل الجمع الأحدث الاشتراك إلى الجزء الساخن الذي يمكن ملاحظته ، لكن العامل القابل للرصد القابل للرصد لا يشترك في مصدره.
7
|
اجابتك
StackExchange.ifUsing ("Editor"، function () {
StackExchange.using ("externalEditor"، function () {
StackExchange.using ("snippets"، function () {
StackExchange.snippets.init () ،
}) ؛
}) ؛
}، "مقتطفات الشفرة")؛
StackExchange.ready (الوظيفة () {
var channelOptions = {
العلامات: "" .split ("")،
المعرف: "1"
} ؛
initTagRenderer ("". split ("")، "" .split ("")، channelOptions) ؛
StackExchange.using ("externalEditor"، function () {
// يجب إطلاق المحرر بعد المقتطفات ، إذا تم تمكين المقتطفات
إذا (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using ("snippets"، function () {
createEditor () ،
}) ؛
}
آخر {
createEditor () ،
}
}) ؛
دالة createEditor () {
StackExchange.prepareEditor ({
useStacks محرر: خطأ ،
النوع: "إجابة" ،
autoActivateHeartbeat: خطأ ،
convertImagesToLinks: صحيح ،
noModals: صحيح ،
showLowRepImageUpload تحذير: صحيح ،
السمعة في PostImages: 10 ،
منع bindNav: صحيح ،
postfix: ""،
imageUploader: {
brandingHtml: "بدعم من \ u003ca href = \" https: //imgur.com/ \ "\ u003e \ u003csvg class = \" svg-icon \ "width = \" 50 \ "height = \" 18 \ "viewBox = \ "0 0 50 18 \" fill = \ "none \" xmlns = \ "http: //www.w3.org/2000/svg \" \ u003e \ u003cpath d = \ "M46.1709 9.17788C46.1709 8.26454 46.2665 7.94324 47.1084 7.58816C47.4091 7.46349 47.7169 7.36433 48.0099 7.26993C48.9099 6.97997 49.672 6.73443 49.672 5.93063C49.672 5.22043 48.9832 4.61182 48.1414 4.61182C47.4335 4.61182 46.7256 4.916 4.928 46.0943.7562 4.61182 46.7256 4.916 4.928 46.0943 5.507 4.61189 46.7256 4.916 4.928 46.0943.7562 4.61182 43.1481 6.59048V11.9512C43.1481 13.2535 43.6264 13.8962 44.6595 13.8962C45.6924 13.8962 46.1709 13.2535 46.1709 11.9512V9.17788Z \ "/ \ u003e \ u003cpath d = \" M32.492 10.1419434.04.018 14.695.92 41.5985 12.6954 41.5985 10.1419V6.59049C41.5985 5.28821 41.1394 4.66232 40.1061 4.66232C39.0732 4.66232 38.5948 5.28821 38.5948 6.59049V9.60062C38.5948 10.8521 38.2696 11.5455 37.0451 11.545.55.820 521 35.4954 9.60062V6.59049C35.4954 5.28821 35.0173 4.66232 34.0034 4.66232C32.9703 4.66232 32.492 5.28821 32.492 6.59049V10.1419Z \ "/ \ u003e \ u003cpath fill-rule = \" evenodd \ "clip-rule = \" evenodd \ " = \ "M25.6622 17.6335C27.8049 17.6335 29.3739 16.9402 30.2537 15.6379C30.8468 14.7755 30.9615 13.5579 30.961511.9512V6.59049C30.9615 5.28821 30.4833 4.66231 29.4502 4.66231C28.9913 4.66231 28.4555 4.94978 28.1109 5.50789C27.499 4.86533 26.7335 4.56087 25.7005 4.56087C23.1369 4.56087 21.0134 6.57349 21.0134.0134.97932.921.499 12.6616C28.1109 12.7229 28.1161 12.7799 12.8854 28.1301 28.121 12.8346C28.1256 12.9342 28.1301 14.4373 27.2502 15.2321 12.983C28.1301 25،777 15.2321C24.8349 15.2321 24.1352 14.9821 23.5661 14.6393 22.8472 14.5218 14.7787C23.176 22.5437 14.5218 21.2429 15.0123 14.5218C21.7977 21.2429 15.6887C21 .2429 16.7375 22.9072 17.6335 25.6622 17.6335ZM24.1317 9.27932C24.1317 7.94324 24.9928 7.09766 26.1024 7.09766C27.2119 7.09766 28.0918 7.94324 28.0918 9.27932C28.0918 10.6321 27.2311 11.5116 26.1024 11.5116C113.924.13 \ u003cpath d = \ "M16.8045 11.9512C16.8045 13.2535 17.2637 13.8962 18.2965 13.8962C19.3298 13.8962 19.8079 13.2535 19.8079 11.9512V8.12928C19.8079 5.82936 18.4879 4.62866 16.4027 4.62866C15.1594 4.62866 14.279 4.98375 13.3609 5.88013C12.653 5.05154 11.6581 4.62866 10.3573 4.62866C9.34336 4.62866 8.57809 4.89931 7.9466 5.5079C7.58314 4.9328 7.10207 4.66232115. 5.47873 13.8962 6.51203 13.8962C7.54479 13.8962 8.0232 13.2535 8.0232 11.9512V8.90741C8.0232 7.58817 8.44431 6.91179 9.53458 6.91179C10.5104 6.91179 10.893 7.58817 10.893 8.94108V11.9512C10.811 13.87.85 11.3128V 11.9512C10.811 13.87.85 11.3152V11.9512C10.811 13.87.85 11.3128V 90741C13.9157 7.58817 14.3365 6.91179 15.4269 6.91179C16.4027 6.91179 16.8045 7.58817 16.8045 8.94108V11.9512Z \ "/ \ u003e \ u003cpath d = \" M3.31675 6.59049C3.31675 5.28821 2.83566 4.66232 1.802471 0.349 V11.9512C0.313354 13.2535 0.791758 13.8962 1.82471 13.8962C2.85798 13.8962 3.31675 13.2535 3.31675 11.9512V6.59049Z \ "/ \ u003e \ u003cpath d = \" M1.87209 0.400291C0.843612 0.400291 0 1.1159 0 1.98861C0 2.87869 0.822846 3.57676 1.87209 3.57676C2.90056 3.57676 3.7234 2.87869 3.7234 1.98861C3.7234 1.1159 2.90056 0.400291 1.87209 0.400291Z \ "fill = \" # 1BB76E \ "/ \ u00c / u00c / s \ u003e "،
contentPolicyHtml: "مساهمات المستخدم مرخصة بموجب \ u003ca href = \" https: //stackoverflow.com/help/licensing \ "\ u003ecc by-sa \ u003c / a \ u003e \ u003ca href = \" https://stackoverflow.com / legal / content-policy \ "\ u003e (سياسة المحتوى) \ u003c / a \ u003e" ،
allowUrls: صحيح
} ،
onDemand: صحيح ،
discardSelector: ".discard-answer"
، على الفور ، شووماركداونيلب: صحيح ، enableTables: صحيح ، enableSnippets: صحيح
}) ؛
}
}) ؛
نشكرك على المساهمة في إجابة Stack Overflow!
من فضلك تأكد من الإجابة على السؤال. قدم التفاصيل وشارك بأبحاثك!
لكن تجنب ...
طلب المساعدة أو التوضيح أو الرد على إجابات أخرى.
الإدلاء بتصريحات تستند إلى الرأي ؛ دعمهم بالمراجع أو الخبرة الشخصية.
لمعرفة المزيد ، راجع نصائحنا حول كتابة إجابات رائعة.
تم حفظ المسودة
تم تجاهل المسودة
الاشتراك أو تسجيل الدخول
StackExchange.ready (الوظيفة () {
StackExchange.helpers.onClickDraftSave ('# login-link') ؛
}) ؛
سجل باستخدام جوجل
قم بالتسجيل باستخدام Facebook
قم بالتسجيل باستخدام البريد الإلكتروني وكلمة المرور
يقدم
انشر كضيف
اسم
بريد الالكتروني
مطلوب ، لكن لم يظهر قط
StackExchange. جاهز (
وظيفة () {
StackExchange.openid.initPostLogin ('new-post-login'، 'https٪ 3a٪ 2f٪ 2fstackoverflow.com٪ 2fquestions٪ 2f64950463٪ 2fhow-do-rxswift-worker-effect-resubscribes٪ 23new-answer'، 'question_page' ) ؛
}
) ؛
انشر كضيف
اسم
بريد الالكتروني
مطلوب ، لكن لم يظهر قط
انشر إجابتك
تجاهل
بالنقر فوق "نشر إجابتك" ، فإنك توافق على شروط الخدمة وسياسة الخصوصية وسياسة ملفات تعريف الارتباط الخاصة بنا
ليس الجواب الذي تبحث عنه؟ تصفح الأسئلة الأخرى الموسومة بـ ios swift5 rx-swift أو اطرح سؤالك الخاص.